﻿using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Reactive.Subjects;

namespace Provider.YahooStock
{
    public class YahooStockSubscriberComponent : ISubscriberComponent<IYahooStockKey,IYahooStockValue>
    {
        private Subject<KeyValuePair<IYahooStockKey, IYahooStockValue>> _updates = new Subject<KeyValuePair<IYahooStockKey, IYahooStockValue>>();
        
        public void Dispose()
        {
            throw new NotImplementedException();
        }

        public void Subscribe(IYahooStockKey key)
        {
            //when subscribe .... onNext _updates
            throw new NotImplementedException();
        }

        public void UnSubscribe(IYahooStockKey key)
        {
            throw new NotImplementedException();
        }

        public KeyValuePair<IYahooStockKey, IYahooStockValue> GetIntialValue(IYahooStockKey key)
        {
            throw new NotImplementedException();
        }

        public IObservable<KeyValuePair<IYahooStockKey, IYahooStockValue>> Updates
        {
            get { return _updates; }
        }


        public void Initialise(IProviderInitialiser initialiser)
        {
            initialiser.Initialise();
        }
    }
}
